package data.platform.common.service.command;

import data.platform.common.stream.aggregates.Rule;
import reactor.core.publisher.Mono;

public interface RuleScheduleService {

    Mono<Rule> createOrUpdateRule(Rule rule);

    Mono<String> startRule(String ruleId);

    Mono<String> pauseRule(String ruleId);
}
